package com.light.dp.flink.config.dto;

import lombok.Data;

import java.io.Serializable;
import java.util.List;

@Data
public class ColumnMapping implements Serializable {
    private String sourceColumn;
    private String targetColumn;
    private Boolean isTargetPrimaryKey = false;

    public ColumnMapping(String sourceColumn, String targetColumn) {
        this.sourceColumn = sourceColumn;
        this.targetColumn = targetColumn;
    }

    public ColumnMapping(String sourceColumn, String targetColumn, Boolean isTargetPrimaryKey) {
        this.sourceColumn = sourceColumn;
        this.targetColumn = targetColumn;
        this.isTargetPrimaryKey = isTargetPrimaryKey;
    }
}